from mapreduce import operation as op

def process(entity):
  # change entity
  yield op.db.Put(entity)

def process(entity):
  yield op.db.Delete(entity)
